package HandshakeJoin;

import java.util.concurrent.TimeUnit;
import org.apache.s4.core.adapter.AdapterApp;

public class QueryProxyApp extends AdapterApp
{
    @Override
    protected void onInit() {
        setKeyFinder(new QueryRequestKeyFinder());
        super.onInit();

        RequestConverter streamConvertor = createPE(RequestConverter.class);
        streamConvertor.setOutputStream(getRemoteStream()).setJoinId("1")
                .setTimerInterval(10, TimeUnit.SECONDS).setSingleton(true);
    }

    @Override
    protected void onStart() {}

    @Override
    protected void onClose() {}
}